stream_throttle
Provides a
Rust
Stream
combinator, to limit the rate at which items are produced.
Key Features
- Throttling is implemented via
poll()
, and not via any sort of buffering. - The throttling behaviour can be applied to both
Stream
's andFuture
's. - Multiple streams/futures can be throttled together as a group.
- Feature flags to use various timer implementations.
Feature Flags
timer-tokio
: Uses thetokio::time::delay_for()
timer.timer-futures-timer
: Uses thefutures_timer::Delay
timer.
If you don't use the default timer (tokio
), make sure to set default-features = false
in your Cargo.toml
, when you add stream_throttle
as a dependency.
Example throttling of Stream
// allow no more than 5 items every 1 second
let rate = new;
let pool = new;
let work = repeat
.throttle
.then
.for_each;
work.await;
Example throttling of Future
let rate = new;
let pool = new;
let work = pool.queue
.then;
work.await;